package com.choudou5.webflux.service;

import com.choudou5.webflux.dao.DemoDao;
import com.choudou5.webflux.dto.DemoReq;
import lombok.AllArgsConstructor;
import reactor.core.publisher.Flux;

@AllArgsConstructor
public class DefaultDemoService implements DemoService {

    private DemoDao demoDao;

    @Override
    public Flux<Long> getIncrement(String type, DemoReq req) {
        return demoDao.getIncrement(type, req.getUserId());
    }
}
